package com.zpl.mq.consumer.api;

/**
 * @author zhupanlin
 * @version 1.0
 * @description: TODO
 * @date 2024/9/7 17:31
 */
public interface IMqConsumerListener {

    /**
     * 消费
     * @param mqMessage 消息体
     * @param context 上下文
     * @return 结果
     */
    ConsumerStatus consumer(final MqMessage mqMessage,
                            final IMqConsumerListenerContext context);
    
}
